#使用SQL语句和pymysql库完成综合案例的开发
from file_define import TextFileReader,JsonFileReader
from data_define import Record
from pymysql import Connection
text_file_reader=TextFileReader("D:/2011年1月销售数据.txt")
json_file_reader=JsonFileReader("D:/2011年2月销售数据JSON.txt")

jan_data:list[Record]=text_file_reader.read_data()
feb_data:list[Record]=json_file_reader.read_data()

all_data:list[Record]=jan_data+feb_data
#构建MySQL链接对象
conn=Connection(
    host='localhost',
    port=3306,
    user='root',
    password='zc050628',
    autocommit=True
)
#获得游标对象
cursor=conn.cursor()
#选择数据库
conn.select_db('py_sql')
#组织sql语句
for record in all_data:
    sql=(f'insert into orders(order_data,order_id,money,province) '
         f"values('{record.data}','{record.order_id}',{record.money},'{record.province}')"
    #执行sql语句
    cursor.execute(sql)
#关闭MySQL链接对象
conn.close()